from celery import Celery

# 为celery使用django配置文件进行设置(将django和celery关联起来)
# Django(发布任务并调用结果)-->celery(发送异步任务)-->云通讯(发送短信的方法调用)
import os

# 找这个键，如果没有，则添加这个键，并写入值
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    # 添加这个键，指定Django的配置文件（与manage.py指定的路径一致）
    os.environ['DJANGO_SETTINGS_MODULE'] = 'haoke_mall.settings.config'

# 创建celery应用（创建异步任务的实例）
app = Celery('haoke27')

# 导入celery配置（任务的存储队列）
app.config_from_object('celery_tasks.config')

# 自动注册celery任务（指定任务：发送短信验证码，可以是多个,如增加了发送邮箱任务）
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])